package data.platform.common.service.query;

import data.platform.common.stream.aggregates.WindowAggregateItemVO;
import data.platform.common.stream.aggregates.WindowResultVO;
import reactor.core.publisher.Flux;

public interface WindowAggregateQueryService {

    // key: tagJson
    Flux<WindowAggregateItemVO> queryAggregateItems(String ruleId);

    Flux<WindowResultVO> queryWindowResult(String ruleId);
}
